<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "https://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/>
<meta http-equiv="X-UA-Compatible" content="IE=9"/>
<meta name="generator" content="Doxygen 1.8.15"/>
<meta name="viewport" content="width=device-width, initial-scale=1"/>
<title>QuantumLibrary: /bb/mbigc/mbig5696/git/quantum_external/src/quantum_dispatcher.h Source File</title>
<link href="../../tabs.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="../../jquery.js"></script>
<script type="text/javascript" src="../../dynsections.js"></script>
<link href="../../navtree.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="../../resize.js"></script>
<script type="text/javascript" src="../../navtreedata.js"></script>
<script type="text/javascript" src="../../navtree.js"></script>
<script type="text/javascript">
/* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&amp;dn=gpl-2.0.txt GPL-v2 */
  $(document).ready(initResizable);
/* @license-end */</script>
<link href="../../search/search.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="../../search/searchdata.js"></script>
<script type="text/javascript" src="../../search/search.js"></script>
<link href="../../doxygen.css" rel="stylesheet" type="text/css" />
</head>
<body>
<div id="top"><!-- do not remove this div, it is closed by doxygen! -->
<div id="titlearea">
<table cellspacing="0" cellpadding="0">
 <tbody>
 <tr style="height: 56px;">
  <td id="projectalign" style="padding-left: 0.5em;">
   <div id="projectname">QuantumLibrary
   </div>
  </td>
 </tr>
 </tbody>
</table>
</div>
<!-- end header part -->
<!-- Generated by Doxygen 1.8.15 -->
<script type="text/javascript">
/* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&amp;dn=gpl-2.0.txt GPL-v2 */
var searchBox = new SearchBox("searchBox", "../../search",false,'Search');
/* @license-end */
</script>
<script type="text/javascript" src="../../menudata.js"></script>
<script type="text/javascript" src="../../menu.js"></script>
<script type="text/javascript">
/* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&amp;dn=gpl-2.0.txt GPL-v2 */
$(function() {
  initMenu('../../',true,false,'search.php','Search');
  $(document).ready(function() { init_search(); });
});
/* @license-end */</script>
<div id="main-nav"></div>
</div><!-- top -->
<div id="side-nav" class="ui-resizable side-nav-resizable">
  <div id="nav-tree">
    <div id="nav-tree-contents">
      <div id="nav-sync" class="sync"></div>
    </div>
  </div>
  <div id="splitbar" style="-moz-user-select:none;" 
       class="ui-resizable-handle">
  </div>
</div>
<script type="text/javascript">
/* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&amp;dn=gpl-2.0.txt GPL-v2 */
$(document).ready(function(){initNavTree('de/d2f/quantum__dispatcher_8h_source.html','../../');});
/* @license-end */
</script>
<div id="doc-content">
<!-- window showing the filter options -->
<div id="MSearchSelectWindow"
     onmouseover="return searchBox.OnSearchSelectShow()"
     onmouseout="return searchBox.OnSearchSelectHide()"
     onkeydown="return searchBox.OnSearchSelectKey(event)">
</div>

<!-- iframe showing the search results (closed by default) -->
<div id="MSearchResultsWindow">
<iframe src="javascript:void(0)" frameborder="0" 
        name="MSearchResults" id="MSearchResults">
</iframe>
</div>

<div class="header">
  <div class="headertitle">
<div class="title">quantum_dispatcher.h</div>  </div>
</div><!--header-->
<div class="contents">
<div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno">    1</span>&#160;<span class="comment">/*</span></div><div class="line"><a name="l00002"></a><span class="lineno">    2</span>&#160;<span class="comment">** Copyright 2018 Bloomberg Finance L.P.</span></div><div class="line"><a name="l00003"></a><span class="lineno">    3</span>&#160;<span class="comment">**</span></div><div class="line"><a name="l00004"></a><span class="lineno">    4</span>&#160;<span class="comment">** Licensed under the Apache License, Version 2.0 (the &quot;License&quot;);</span></div><div class="line"><a name="l00005"></a><span class="lineno">    5</span>&#160;<span class="comment">** you may not use this file except in compliance with the License.</span></div><div class="line"><a name="l00006"></a><span class="lineno">    6</span>&#160;<span class="comment">** You may obtain a copy of the License at</span></div><div class="line"><a name="l00007"></a><span class="lineno">    7</span>&#160;<span class="comment">**</span></div><div class="line"><a name="l00008"></a><span class="lineno">    8</span>&#160;<span class="comment">**     http://www.apache.org/licenses/LICENSE-2.0</span></div><div class="line"><a name="l00009"></a><span class="lineno">    9</span>&#160;<span class="comment">**</span></div><div class="line"><a name="l00010"></a><span class="lineno">   10</span>&#160;<span class="comment">** Unless required by applicable law or agreed to in writing, software</span></div><div class="line"><a name="l00011"></a><span class="lineno">   11</span>&#160;<span class="comment">** distributed under the License is distributed on an &quot;AS IS&quot; BASIS,</span></div><div class="line"><a name="l00012"></a><span class="lineno">   12</span>&#160;<span class="comment">** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span></div><div class="line"><a name="l00013"></a><span class="lineno">   13</span>&#160;<span class="comment">** See the License for the specific language governing permissions and</span></div><div class="line"><a name="l00014"></a><span class="lineno">   14</span>&#160;<span class="comment">** limitations under the License.</span></div><div class="line"><a name="l00015"></a><span class="lineno">   15</span>&#160;<span class="comment">*/</span></div><div class="line"><a name="l00016"></a><span class="lineno">   16</span>&#160;<span class="preprocessor">#ifndef BLOOMBERG_QUANTUM_DISPATCHER_H</span></div><div class="line"><a name="l00017"></a><span class="lineno">   17</span>&#160;<span class="preprocessor">#define BLOOMBERG_QUANTUM_DISPATCHER_H</span></div><div class="line"><a name="l00018"></a><span class="lineno">   18</span>&#160;</div><div class="line"><a name="l00019"></a><span class="lineno">   19</span>&#160;<span class="preprocessor">#include &lt;quantum/quantum_context.h&gt;</span></div><div class="line"><a name="l00020"></a><span class="lineno">   20</span>&#160;<span class="preprocessor">#include &lt;quantum/quantum_configuration.h&gt;</span></div><div class="line"><a name="l00021"></a><span class="lineno">   21</span>&#160;<span class="preprocessor">#include &lt;quantum/quantum_macros.h&gt;</span></div><div class="line"><a name="l00022"></a><span class="lineno">   22</span>&#160;<span class="preprocessor">#include &lt;iterator&gt;</span></div><div class="line"><a name="l00023"></a><span class="lineno">   23</span>&#160;<span class="preprocessor">#include &lt;chrono&gt;</span></div><div class="line"><a name="l00024"></a><span class="lineno">   24</span>&#160;</div><div class="line"><a name="l00025"></a><span class="lineno">   25</span>&#160;<span class="keyword">namespace </span><a class="code" href="../../d6/db9/namespaceBloomberg.html">Bloomberg</a> {</div><div class="line"><a name="l00026"></a><span class="lineno">   26</span>&#160;<span class="keyword">namespace </span>quantum {</div><div class="line"><a name="l00027"></a><span class="lineno">   27</span>&#160;</div><div class="line"><a name="l00028"></a><span class="lineno">   28</span>&#160;<span class="comment">//==============================================================================================</span></div><div class="line"><a name="l00029"></a><span class="lineno">   29</span>&#160;<span class="comment">//                                 class Dispatcher</span></div><div class="line"><a name="l00030"></a><span class="lineno">   30</span>&#160;<span class="comment">//==============================================================================================</span></div><div class="line"><a name="l00034"></a><span class="lineno"><a class="line" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html">   34</a></span>&#160;<span class="comment"></span><span class="keyword">class </span><a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html">Dispatcher</a> : <span class="keyword">public</span> <a class="code" href="../../d2/d41/namespaceITerminate.html">ITerminate</a></div><div class="line"><a name="l00035"></a><span class="lineno">   35</span>&#160;{</div><div class="line"><a name="l00036"></a><span class="lineno">   36</span>&#160;<span class="keyword">public</span>:</div><div class="line"><a name="l00037"></a><span class="lineno"><a class="line" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#aa6e5a6cd4905afe2c1d7c9bc620b321e">   37</a></span>&#160;    <span class="keyword">using</span> <a class="code" href="../../de/de9/structBloomberg_1_1quantum_1_1ThreadContextTag.html">ContextTag</a> = <a class="code" href="../../de/de9/structBloomberg_1_1quantum_1_1ThreadContextTag.html">ThreadContextTag</a>;</div><div class="line"><a name="l00038"></a><span class="lineno">   38</span>&#160;    </div><div class="line"><a name="l00048"></a><span class="lineno">   48</span>&#160;    DEPRECATED <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a2871b47899d42838de63bbc94f088bbe">Dispatcher</a>(<span class="keywordtype">int</span> numCoroutineThreads = -1,</div><div class="line"><a name="l00049"></a><span class="lineno">   49</span>&#160;                          <span class="keywordtype">int</span> numIoThreads = 5,</div><div class="line"><a name="l00050"></a><span class="lineno">   50</span>&#160;                          <span class="keywordtype">bool</span> pinCoroutineThreadsToCores = <span class="keyword">false</span>);</div><div class="line"><a name="l00051"></a><span class="lineno">   51</span>&#160;    </div><div class="line"><a name="l00054"></a><span class="lineno">   54</span>&#160;    <span class="keyword">explicit</span> <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a2871b47899d42838de63bbc94f088bbe">Dispatcher</a>(<span class="keyword">const</span> <a class="code" href="../../db/dda/classBloomberg_1_1quantum_1_1Configuration.html">Configuration</a>&amp; config);</div><div class="line"><a name="l00055"></a><span class="lineno">   55</span>&#160;    </div><div class="line"><a name="l00059"></a><span class="lineno">   59</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a2ce33c9ae341c9592a0d1c74b5ef30b3">~Dispatcher</a>();</div><div class="line"><a name="l00060"></a><span class="lineno">   60</span>&#160;    </div><div class="line"><a name="l00074"></a><span class="lineno">   74</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>RET = int, <span class="keyword">class </span>FUNC, <span class="keyword">class </span>... ARGS&gt;</div><div class="line"><a name="l00075"></a><span class="lineno">   75</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;RET&gt;</a></div><div class="line"><a name="l00076"></a><span class="lineno">   76</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a5c160004cdf4b6c0a18bdaf138b650ac">post</a>(FUNC&amp;&amp; func, ARGS&amp;&amp;... args);</div><div class="line"><a name="l00077"></a><span class="lineno">   77</span>&#160;    </div><div class="line"><a name="l00094"></a><span class="lineno">   94</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>RET = int, <span class="keyword">class </span>FUNC, <span class="keyword">class </span>... ARGS&gt;</div><div class="line"><a name="l00095"></a><span class="lineno">   95</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;RET&gt;</a></div><div class="line"><a name="l00096"></a><span class="lineno">   96</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a5c160004cdf4b6c0a18bdaf138b650ac">post</a>(<span class="keywordtype">int</span> queueId, <span class="keywordtype">bool</span> isHighPriority, FUNC&amp;&amp; func, ARGS&amp;&amp;... args);</div><div class="line"><a name="l00097"></a><span class="lineno">   97</span>&#160;    </div><div class="line"><a name="l00109"></a><span class="lineno">  109</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>RET = int, <span class="keyword">class </span>FUNC, <span class="keyword">class </span>... ARGS&gt;</div><div class="line"><a name="l00110"></a><span class="lineno">  110</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;RET&gt;</a></div><div class="line"><a name="l00111"></a><span class="lineno">  111</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a1ea6c5d5a3355cc92a1ac989ba0731e5">postFirst</a>(FUNC&amp;&amp; func, ARGS&amp;&amp;... args);</div><div class="line"><a name="l00112"></a><span class="lineno">  112</span>&#160;    </div><div class="line"><a name="l00129"></a><span class="lineno">  129</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>RET = int, <span class="keyword">class </span>FUNC, <span class="keyword">class </span>... ARGS&gt;</div><div class="line"><a name="l00130"></a><span class="lineno">  130</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;RET&gt;</a></div><div class="line"><a name="l00131"></a><span class="lineno">  131</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a1ea6c5d5a3355cc92a1ac989ba0731e5">postFirst</a>(<span class="keywordtype">int</span> queueId, <span class="keywordtype">bool</span> isHighPriority, FUNC&amp;&amp; func, ARGS&amp;&amp;... args);</div><div class="line"><a name="l00132"></a><span class="lineno">  132</span>&#160;    </div><div class="line"><a name="l00143"></a><span class="lineno">  143</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>RET = int, <span class="keyword">class </span>FUNC, <span class="keyword">class </span>... ARGS&gt;</div><div class="line"><a name="l00144"></a><span class="lineno">  144</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#a742e0d39218b80ae60f30d47ae58bbc9">ThreadFuturePtr&lt;RET&gt;</a></div><div class="line"><a name="l00145"></a><span class="lineno">  145</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a24ea411ae684451cb800f2ef705095e3">postAsyncIo</a>(FUNC&amp;&amp; func, ARGS&amp;&amp;... args);</div><div class="line"><a name="l00146"></a><span class="lineno">  146</span>&#160;    </div><div class="line"><a name="l00161"></a><span class="lineno">  161</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>RET = int, <span class="keyword">class </span>FUNC, <span class="keyword">class </span>... ARGS&gt;</div><div class="line"><a name="l00162"></a><span class="lineno">  162</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#a742e0d39218b80ae60f30d47ae58bbc9">ThreadFuturePtr&lt;RET&gt;</a></div><div class="line"><a name="l00163"></a><span class="lineno">  163</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a24ea411ae684451cb800f2ef705095e3">postAsyncIo</a>(<span class="keywordtype">int</span> queueId, <span class="keywordtype">bool</span> isHighPriority, FUNC&amp;&amp; func, ARGS&amp;&amp;... args);</div><div class="line"><a name="l00164"></a><span class="lineno">  164</span>&#160;    </div><div class="line"><a name="l00176"></a><span class="lineno">  176</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class</span> RET = <span class="keywordtype">int</span>, <span class="keyword">class</span> INPUT_IT, <span class="keyword">class</span> = Traits::IsInputIterator&lt;INPUT_IT&gt;&gt;</div><div class="line"><a name="l00177"></a><span class="lineno">  177</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;std::vector&lt;RET&gt;</a>&gt;</div><div class="line"><a name="l00178"></a><span class="lineno">  178</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#af9281ee1e58963babb99304bc9cf3f16">forEach</a>(INPUT_IT first, INPUT_IT last, <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a510a24630512ab725361c0250bbf882e">Functions::ForEachFunc&lt;RET, INPUT_IT&gt;</a> func);</div><div class="line"><a name="l00179"></a><span class="lineno">  179</span>&#160;    </div><div class="line"><a name="l00182"></a><span class="lineno">  182</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class</span> RET = <span class="keywordtype">int</span>, <span class="keyword">class</span> INPUT_IT&gt;</div><div class="line"><a name="l00183"></a><span class="lineno">  183</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;std::vector&lt;RET&gt;</a>&gt;</div><div class="line"><a name="l00184"></a><span class="lineno">  184</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#af9281ee1e58963babb99304bc9cf3f16">forEach</a>(INPUT_IT first, <span class="keywordtype">size_t</span> num, <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a510a24630512ab725361c0250bbf882e">Functions::ForEachFunc&lt;RET, INPUT_IT&gt;</a> func);</div><div class="line"><a name="l00185"></a><span class="lineno">  185</span>&#160;    </div><div class="line"><a name="l00193"></a><span class="lineno">  193</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class</span> RET = <span class="keywordtype">int</span>, <span class="keyword">class</span> INPUT_IT, <span class="keyword">class</span> = Traits::IsInputIterator&lt;INPUT_IT&gt;&gt;</div><div class="line"><a name="l00194"></a><span class="lineno">  194</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;std::vector&lt;std::vector&lt;RET&gt;</a>&gt;&gt;</div><div class="line"><a name="l00195"></a><span class="lineno">  195</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a7606eec66e86bb175f090afd92d4f806">forEachBatch</a>(INPUT_IT first, INPUT_IT last, <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a510a24630512ab725361c0250bbf882e">Functions::ForEachFunc&lt;RET, INPUT_IT&gt;</a> func);</div><div class="line"><a name="l00196"></a><span class="lineno">  196</span>&#160;    </div><div class="line"><a name="l00199"></a><span class="lineno">  199</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class</span> RET = <span class="keywordtype">int</span>, <span class="keyword">class</span> INPUT_IT&gt;</div><div class="line"><a name="l00200"></a><span class="lineno">  200</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;std::vector&lt;std::vector&lt;RET&gt;</a>&gt;&gt;</div><div class="line"><a name="l00201"></a><span class="lineno">  201</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a7606eec66e86bb175f090afd92d4f806">forEachBatch</a>(INPUT_IT first, <span class="keywordtype">size_t</span> num, <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a510a24630512ab725361c0250bbf882e">Functions::ForEachFunc&lt;RET, INPUT_IT&gt;</a> func);</div><div class="line"><a name="l00202"></a><span class="lineno">  202</span>&#160;    </div><div class="line"><a name="l00218"></a><span class="lineno">  218</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>KEY,</div><div class="line"><a name="l00219"></a><span class="lineno">  219</span>&#160;              <span class="keyword">class </span>MAPPED_TYPE,</div><div class="line"><a name="l00220"></a><span class="lineno">  220</span>&#160;              <span class="keyword">class </span>REDUCED_TYPE,</div><div class="line"><a name="l00221"></a><span class="lineno">  221</span>&#160;              <span class="keyword">class </span>INPUT_IT,</div><div class="line"><a name="l00222"></a><span class="lineno">  222</span>&#160;              <span class="keyword">class </span>= <a class="code" href="../../d6/d86/structBloomberg_1_1quantum_1_1Traits.html#a426371df215f96d490ba45c21f651468">Traits::IsInputIterator&lt;INPUT_IT&gt;</a>&gt;</div><div class="line"><a name="l00223"></a><span class="lineno">  223</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;std::map&lt;KEY, REDUCED_TYPE&gt;</a>&gt;</div><div class="line"><a name="l00224"></a><span class="lineno">  224</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a6e382dc993e327ec2f27068023390075">mapReduce</a>(INPUT_IT first,</div><div class="line"><a name="l00225"></a><span class="lineno">  225</span>&#160;              INPUT_IT last,</div><div class="line"><a name="l00226"></a><span class="lineno">  226</span>&#160;              <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#af8fdee23da6d53ce304c908981315528">Functions::MapFunc&lt;KEY, MAPPED_TYPE, INPUT_IT&gt;</a> mapper,</div><div class="line"><a name="l00227"></a><span class="lineno">  227</span>&#160;              <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a4f8eb1de73c9ec3661fee4242f1a2a87">Functions::ReduceFunc&lt;KEY, MAPPED_TYPE, REDUCED_TYPE&gt;</a> reducer);</div><div class="line"><a name="l00228"></a><span class="lineno">  228</span>&#160;  </div><div class="line"><a name="l00231"></a><span class="lineno">  231</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>KEY,</div><div class="line"><a name="l00232"></a><span class="lineno">  232</span>&#160;              <span class="keyword">class </span>MAPPED_TYPE,</div><div class="line"><a name="l00233"></a><span class="lineno">  233</span>&#160;              <span class="keyword">class </span>REDUCED_TYPE,</div><div class="line"><a name="l00234"></a><span class="lineno">  234</span>&#160;              <span class="keyword">class </span>INPUT_IT&gt;</div><div class="line"><a name="l00235"></a><span class="lineno">  235</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;std::map&lt;KEY, REDUCED_TYPE&gt;</a>&gt;</div><div class="line"><a name="l00236"></a><span class="lineno">  236</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a6e382dc993e327ec2f27068023390075">mapReduce</a>(INPUT_IT first,</div><div class="line"><a name="l00237"></a><span class="lineno">  237</span>&#160;              <span class="keywordtype">size_t</span> num,</div><div class="line"><a name="l00238"></a><span class="lineno">  238</span>&#160;              <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#af8fdee23da6d53ce304c908981315528">Functions::MapFunc&lt;KEY, MAPPED_TYPE, INPUT_IT&gt;</a> mapper,</div><div class="line"><a name="l00239"></a><span class="lineno">  239</span>&#160;              <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a4f8eb1de73c9ec3661fee4242f1a2a87">Functions::ReduceFunc&lt;KEY, MAPPED_TYPE, REDUCED_TYPE&gt;</a> reducer);</div><div class="line"><a name="l00240"></a><span class="lineno">  240</span>&#160;    </div><div class="line"><a name="l00245"></a><span class="lineno">  245</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>KEY,</div><div class="line"><a name="l00246"></a><span class="lineno">  246</span>&#160;              <span class="keyword">class </span>MAPPED_TYPE,</div><div class="line"><a name="l00247"></a><span class="lineno">  247</span>&#160;              <span class="keyword">class </span>REDUCED_TYPE,</div><div class="line"><a name="l00248"></a><span class="lineno">  248</span>&#160;              <span class="keyword">class </span>INPUT_IT,</div><div class="line"><a name="l00249"></a><span class="lineno">  249</span>&#160;              <span class="keyword">class </span>= <a class="code" href="../../d6/d86/structBloomberg_1_1quantum_1_1Traits.html#a426371df215f96d490ba45c21f651468">Traits::IsInputIterator&lt;INPUT_IT&gt;</a>&gt;</div><div class="line"><a name="l00250"></a><span class="lineno">  250</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;std::map&lt;KEY, REDUCED_TYPE&gt;</a>&gt;</div><div class="line"><a name="l00251"></a><span class="lineno">  251</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a6a528a6d88f8f1bcc2852df50cc05597">mapReduceBatch</a>(INPUT_IT first,</div><div class="line"><a name="l00252"></a><span class="lineno">  252</span>&#160;                   INPUT_IT last,</div><div class="line"><a name="l00253"></a><span class="lineno">  253</span>&#160;                   <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#af8fdee23da6d53ce304c908981315528">Functions::MapFunc&lt;KEY, MAPPED_TYPE, INPUT_IT&gt;</a> mapper,</div><div class="line"><a name="l00254"></a><span class="lineno">  254</span>&#160;                   <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a4f8eb1de73c9ec3661fee4242f1a2a87">Functions::ReduceFunc&lt;KEY, MAPPED_TYPE, REDUCED_TYPE&gt;</a> reducer);</div><div class="line"><a name="l00255"></a><span class="lineno">  255</span>&#160;    </div><div class="line"><a name="l00258"></a><span class="lineno">  258</span>&#160;    <span class="keyword">template</span> &lt;<span class="keyword">class </span>KEY,</div><div class="line"><a name="l00259"></a><span class="lineno">  259</span>&#160;              <span class="keyword">class </span>MAPPED_TYPE,</div><div class="line"><a name="l00260"></a><span class="lineno">  260</span>&#160;              <span class="keyword">class </span>REDUCED_TYPE,</div><div class="line"><a name="l00261"></a><span class="lineno">  261</span>&#160;              <span class="keyword">class </span>INPUT_IT&gt;</div><div class="line"><a name="l00262"></a><span class="lineno">  262</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr&lt;std::map&lt;KEY, REDUCED_TYPE&gt;</a>&gt;</div><div class="line"><a name="l00263"></a><span class="lineno">  263</span>&#160;    <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a6a528a6d88f8f1bcc2852df50cc05597">mapReduceBatch</a>(INPUT_IT first,</div><div class="line"><a name="l00264"></a><span class="lineno">  264</span>&#160;                   <span class="keywordtype">size_t</span> num,</div><div class="line"><a name="l00265"></a><span class="lineno">  265</span>&#160;                   <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#af8fdee23da6d53ce304c908981315528">Functions::MapFunc&lt;KEY, MAPPED_TYPE, INPUT_IT&gt;</a> mapper,</div><div class="line"><a name="l00266"></a><span class="lineno">  266</span>&#160;                   <a class="code" href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a4f8eb1de73c9ec3661fee4242f1a2a87">Functions::ReduceFunc&lt;KEY, MAPPED_TYPE, REDUCED_TYPE&gt;</a> reducer);</div><div class="line"><a name="l00267"></a><span class="lineno">  267</span>&#160;</div><div class="line"><a name="l00271"></a><span class="lineno">  271</span>&#160;    <span class="keywordtype">void</span> <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#ab8715f18ec4dc05c89b0062701ef17a6">terminate</a>() final;</div><div class="line"><a name="l00272"></a><span class="lineno">  272</span>&#160;    </div><div class="line"><a name="l00280"></a><span class="lineno">  280</span>&#160;    <span class="keywordtype">size_t</span> <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a841e9603a79d9feafc91a3a764e8a7d1">size</a>(<a class="code" href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">IQueue</a>::QueueType type = <a class="code" href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">IQueue</a>::QueueType::All,</div><div class="line"><a name="l00281"></a><span class="lineno">  281</span>&#160;                <span class="keywordtype">int</span> queueId = (<span class="keywordtype">int</span>)<a class="code" href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">IQueue</a>::QueueId::All) const;</div><div class="line"><a name="l00282"></a><span class="lineno">  282</span>&#160;    </div><div class="line"><a name="l00290"></a><span class="lineno">  290</span>&#160;    <span class="keywordtype">bool</span> <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a85adfabb7f5d5788de3ef6d8433259f3">empty</a>(<a class="code" href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">IQueue</a>::QueueType type = <a class="code" href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">IQueue</a>::QueueType::All,</div><div class="line"><a name="l00291"></a><span class="lineno">  291</span>&#160;               <span class="keywordtype">int</span> queueId = (<span class="keywordtype">int</span>)<a class="code" href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">IQueue</a>::QueueId::All) const;</div><div class="line"><a name="l00292"></a><span class="lineno">  292</span>&#160;    </div><div class="line"><a name="l00297"></a><span class="lineno">  297</span>&#160;    <span class="keywordtype">void</span> <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#af70d412946a48308687966a3c6089a6d">drain</a>(<a class="code" href="../../d8/dcc/namespacestd.html">std</a>::chrono::milliseconds timeout = <a class="code" href="../../d8/dcc/namespacestd.html">std</a>::chrono::milliseconds::zero());</div><div class="line"><a name="l00298"></a><span class="lineno">  298</span>&#160;    </div><div class="line"><a name="l00304"></a><span class="lineno">  304</span>&#160;    <span class="keywordtype">int</span> <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a2be91ea87c7095558a2e678e750b467d">getNumCoroutineThreads</a>() const;</div><div class="line"><a name="l00305"></a><span class="lineno">  305</span>&#160;    </div><div class="line"><a name="l00310"></a><span class="lineno">  310</span>&#160;    <span class="keywordtype">int</span> <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a0fee5233633dcf411120ce0d9bbe683f">getNumIoThreads</a>() const;</div><div class="line"><a name="l00311"></a><span class="lineno">  311</span>&#160;</div><div class="line"><a name="l00315"></a><span class="lineno">  315</span>&#160;    const <a class="code" href="../../d8/dcc/namespacestd.html">std</a>::pair&lt;<span class="keywordtype">int</span>, <span class="keywordtype">int</span>&gt;&amp; <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a3f75cbfc894f962fcf6ff946154ece0c">getCoroQueueIdRangeForAny</a>() const;</div><div class="line"><a name="l00316"></a><span class="lineno">  316</span>&#160;    </div><div class="line"><a name="l00324"></a><span class="lineno">  324</span>&#160;    <a class="code" href="../../d1/d7b/classBloomberg_1_1quantum_1_1QueueStatistics.html">QueueStatistics</a> <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#afe2948d83722bec051e4547848bfcf0e">stats</a>(<a class="code" href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">IQueue</a>::QueueType type = <a class="code" href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">IQueue</a>::QueueType::All,</div><div class="line"><a name="l00325"></a><span class="lineno">  325</span>&#160;                          <span class="keywordtype">int</span> queueId = (<span class="keywordtype">int</span>)<a class="code" href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">IQueue</a>::QueueId::All);</div><div class="line"><a name="l00326"></a><span class="lineno">  326</span>&#160;    </div><div class="line"><a name="l00328"></a><span class="lineno">  328</span>&#160;    <span class="keywordtype">void</span> <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a5d990ec39694d86dd8f5df1f5c50d65c">resetStats</a>();</div><div class="line"><a name="l00329"></a><span class="lineno">  329</span>&#160;    </div><div class="line"><a name="l00330"></a><span class="lineno">  330</span>&#160;private:</div><div class="line"><a name="l00331"></a><span class="lineno">  331</span>&#160;    template &lt;<a class="code" href="../../d9/d6d/classclass.html">class</a> RET, <a class="code" href="../../d9/d6d/classclass.html">class</a> FUNC, <a class="code" href="../../d9/d6d/classclass.html">class</a> ... ARGS&gt;</div><div class="line"><a name="l00332"></a><span class="lineno">  332</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">ThreadContextPtr</a>&lt;RET&gt;</div><div class="line"><a name="l00333"></a><span class="lineno">  333</span>&#160;    postImpl(<span class="keywordtype">int</span> queueId, <span class="keywordtype">bool</span> isHighPriority, <a class="code" href="../../df/daf/structBloomberg_1_1quantum_1_1ITask.html">ITask</a>::Type type, FUNC&amp;&amp; func, ARGS&amp;&amp;... args);</div><div class="line"><a name="l00334"></a><span class="lineno">  334</span>&#160;    </div><div class="line"><a name="l00335"></a><span class="lineno">  335</span>&#160;    template &lt;<a class="code" href="../../d9/d6d/classclass.html">class</a> RET, <a class="code" href="../../d9/d6d/classclass.html">class</a> FUNC, <a class="code" href="../../d9/d6d/classclass.html">class</a> ... ARGS&gt;</div><div class="line"><a name="l00336"></a><span class="lineno">  336</span>&#160;    <a class="code" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#a742e0d39218b80ae60f30d47ae58bbc9">ThreadFuturePtr</a>&lt;RET&gt;</div><div class="line"><a name="l00337"></a><span class="lineno">  337</span>&#160;    postAsyncIoImpl(<span class="keywordtype">int</span> queueId, <span class="keywordtype">bool</span> isHighPriority, FUNC&amp;&amp; func, ARGS&amp;&amp;... args);</div><div class="line"><a name="l00338"></a><span class="lineno">  338</span>&#160;    </div><div class="line"><a name="l00339"></a><span class="lineno">  339</span>&#160;    <span class="comment">//Members</span></div><div class="line"><a name="l00340"></a><span class="lineno">  340</span>&#160;    <a class="code" href="../../da/daa/classBloomberg_1_1quantum_1_1DispatcherCore.html">DispatcherCore</a>              _dispatcher;</div><div class="line"><a name="l00341"></a><span class="lineno">  341</span>&#160;    <span class="keywordtype">bool</span>                        _drain;</div><div class="line"><a name="l00342"></a><span class="lineno">  342</span>&#160;    <a class="code" href="../../d8/dcc/namespacestd.html">std</a>::atomic_flag            _terminated;</div><div class="line"><a name="l00343"></a><span class="lineno">  343</span>&#160;};</div><div class="line"><a name="l00344"></a><span class="lineno">  344</span>&#160;</div><div class="line"><a name="l00345"></a><span class="lineno"><a class="line" href="../../dc/d48/namespaceBloomberg_1_1quantum.html#a758f35e0635ed43756e7992c606e8333">  345</a></span>&#160;using <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html">TaskDispatcher</a> = <a class="code" href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html">Dispatcher</a>; <span class="comment">//alias</span></div><div class="line"><a name="l00346"></a><span class="lineno">  346</span>&#160;</div><div class="line"><a name="l00347"></a><span class="lineno">  347</span>&#160;}}</div><div class="line"><a name="l00348"></a><span class="lineno">  348</span>&#160;</div><div class="line"><a name="l00349"></a><span class="lineno">  349</span>&#160;<span class="preprocessor">#include &lt;quantum/impl/quantum_dispatcher_impl.h&gt;</span></div><div class="line"><a name="l00350"></a><span class="lineno">  350</span>&#160;</div><div class="line"><a name="l00351"></a><span class="lineno">  351</span>&#160;<span class="preprocessor">#endif //BLOOMBERG_QUANTUM_DISPATCHER_H</span></div><div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_af70d412946a48308687966a3c6089a6d"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#af70d412946a48308687966a3c6089a6d">Bloomberg::quantum::Dispatcher::drain</a></div><div class="ttdeci">void drain(std::chrono::milliseconds timeout=std::chrono::milliseconds::zero())</div><div class="ttdoc">Drains all queues on this dispatcher object.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:235</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a7606eec66e86bb175f090afd92d4f806"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a7606eec66e86bb175f090afd92d4f806">Bloomberg::quantum::Dispatcher::forEachBatch</a></div><div class="ttdeci">ThreadContextPtr&lt; std::vector&lt; std::vector&lt; RET &gt; &gt; &gt; forEachBatch(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc&lt; RET, INPUT_IT &gt; func)</div><div class="ttdoc">The batched version of forEach(). This function applies the given unary function to all the elements ...</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:127</div></div>
<div class="ttc" id="namespaceBloomberg_html"><div class="ttname"><a href="../../d6/db9/namespaceBloomberg.html">Bloomberg</a></div><div class="ttdef"><b>Definition:</b> quantum_buffer_impl.h:22</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_afe2948d83722bec051e4547848bfcf0e"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#afe2948d83722bec051e4547848bfcf0e">Bloomberg::quantum::Dispatcher::stats</a></div><div class="ttdeci">QueueStatistics stats(IQueue::QueueType type=IQueue::QueueType::All, int queueId=(int) IQueue::QueueId::All)</div><div class="ttdoc">Returns a statistics object for the specified type and queue id.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:285</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a2ce33c9ae341c9592a0d1c74b5ef30b3"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a2ce33c9ae341c9592a0d1c74b5ef30b3">Bloomberg::quantum::Dispatcher::~Dispatcher</a></div><div class="ttdeci">~Dispatcher()</div><div class="ttdoc">Destructor.</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a5c160004cdf4b6c0a18bdaf138b650ac"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a5c160004cdf4b6c0a18bdaf138b650ac">Bloomberg::quantum::Dispatcher::post</a></div><div class="ttdeci">ThreadContextPtr&lt; RET &gt; post(FUNC &amp;&amp;func, ARGS &amp;&amp;... args)</div><div class="ttdoc">Post a coroutine to run asynchronously.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:52</div></div>
<div class="ttc" id="namespaceITerminate_html"><div class="ttname"><a href="../../d2/d41/namespaceITerminate.html">ITerminate</a></div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1DispatcherCore_html"><div class="ttname"><a href="../../da/daa/classBloomberg_1_1quantum_1_1DispatcherCore.html">Bloomberg::quantum::DispatcherCore</a></div><div class="ttdoc">Class implementing the dispatching logic unto worker threads. Used for both coroutines and IO tasks.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_core.h:45</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_ab8715f18ec4dc05c89b0062701ef17a6"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#ab8715f18ec4dc05c89b0062701ef17a6">Bloomberg::quantum::Dispatcher::terminate</a></div><div class="ttdeci">void terminate() final</div><div class="ttdoc">Signal all threads to immediately terminate and exit. All other pending coroutines and IO tasks will ...</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:212</div></div>
<div class="ttc" id="namespacestd_html"><div class="ttname"><a href="../../d8/dcc/namespacestd.html">std</a></div><div class="ttdef"><b>Definition:</b> quantum_stl_impl.h:23</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a6e382dc993e327ec2f27068023390075"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a6e382dc993e327ec2f27068023390075">Bloomberg::quantum::Dispatcher::mapReduce</a></div><div class="ttdeci">ThreadContextPtr&lt; std::map&lt; KEY, REDUCED_TYPE &gt; &gt; mapReduce(INPUT_IT first, INPUT_IT last, Functions::MapFunc&lt; KEY, MAPPED_TYPE, INPUT_IT &gt; mapper, Functions::ReduceFunc&lt; KEY, MAPPED_TYPE, REDUCED_TYPE &gt; reducer)</div><div class="ttdoc">Implementation of map-reduce functionality.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:153</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a24ea411ae684451cb800f2ef705095e3"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a24ea411ae684451cb800f2ef705095e3">Bloomberg::quantum::Dispatcher::postAsyncIo</a></div><div class="ttdeci">ThreadFuturePtr&lt; RET &gt; postAsyncIo(FUNC &amp;&amp;func, ARGS &amp;&amp;... args)</div><div class="ttdoc">Post a blocking IO (or long running) task to run asynchronously on the IO thread pool.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:88</div></div>
<div class="ttc" id="structBloomberg_1_1quantum_1_1Functions_html_a510a24630512ab725361c0250bbf882e"><div class="ttname"><a href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a510a24630512ab725361c0250bbf882e">Bloomberg::quantum::Functions::ForEachFunc</a></div><div class="ttdeci">std::function&lt; RET(const typename std::iterator_traits&lt; INPUT_IT &gt;::value_type &amp;)&gt; ForEachFunc</div><div class="ttdef"><b>Definition:</b> quantum_functions.h:34</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a6a528a6d88f8f1bcc2852df50cc05597"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a6a528a6d88f8f1bcc2852df50cc05597">Bloomberg::quantum::Dispatcher::mapReduceBatch</a></div><div class="ttdeci">ThreadContextPtr&lt; std::map&lt; KEY, REDUCED_TYPE &gt; &gt; mapReduceBatch(INPUT_IT first, INPUT_IT last, Functions::MapFunc&lt; KEY, MAPPED_TYPE, INPUT_IT &gt; mapper, Functions::ReduceFunc&lt; KEY, MAPPED_TYPE, REDUCED_TYPE &gt; reducer)</div><div class="ttdoc">This version of mapReduce() runs both the mapper and the reducer functions in batches for improved pe...</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:185</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a1ea6c5d5a3355cc92a1ac989ba0731e5"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a1ea6c5d5a3355cc92a1ac989ba0731e5">Bloomberg::quantum::Dispatcher::postFirst</a></div><div class="ttdeci">ThreadContextPtr&lt; RET &gt; postFirst(FUNC &amp;&amp;func, ARGS &amp;&amp;... args)</div><div class="ttdoc">Post the first coroutine in a continuation chain to run asynchronously.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:70</div></div>
<div class="ttc" id="structBloomberg_1_1quantum_1_1Functions_html_af8fdee23da6d53ce304c908981315528"><div class="ttname"><a href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#af8fdee23da6d53ce304c908981315528">Bloomberg::quantum::Functions::MapFunc</a></div><div class="ttdeci">std::function&lt; std::vector&lt; std::pair&lt; KEY, MAPPED_TYPE &gt; &gt;(const typename std::iterator_traits&lt; INPUT_IT &gt;::value_type &amp;)&gt; MapFunc</div><div class="ttdef"><b>Definition:</b> quantum_functions.h:37</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html">Bloomberg::quantum::Dispatcher</a></div><div class="ttdoc">Parallel execution engine used to run coroutines or IO tasks asynchronously. This class is the main e...</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher.h:34</div></div>
<div class="ttc" id="structBloomberg_1_1quantum_1_1IQueue_html"><div class="ttname"><a href="../../d2/db0/structBloomberg_1_1quantum_1_1IQueue.html">Bloomberg::quantum::IQueue</a></div><div class="ttdoc">Interface to a task queue. For internal use only.</div><div class="ttdef"><b>Definition:</b> quantum_iqueue.h:33</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1QueueStatistics_html"><div class="ttname"><a href="../../d1/d7b/classBloomberg_1_1quantum_1_1QueueStatistics.html">Bloomberg::quantum::QueueStatistics</a></div><div class="ttdoc">Provides various counters related to queues and task execution.</div><div class="ttdef"><b>Definition:</b> quantum_queue_statistics.h:30</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Configuration_html"><div class="ttname"><a href="../../db/dda/classBloomberg_1_1quantum_1_1Configuration.html">Bloomberg::quantum::Configuration</a></div><div class="ttdef"><b>Definition:</b> quantum_configuration.h:31</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a85adfabb7f5d5788de3ef6d8433259f3"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a85adfabb7f5d5788de3ef6d8433259f3">Bloomberg::quantum::Dispatcher::empty</a></div><div class="ttdeci">bool empty(IQueue::QueueType type=IQueue::QueueType::All, int queueId=(int) IQueue::QueueId::All) const</div><div class="ttdoc">Check if the specified type and queue id is empty (i.e. there are no running tasks)</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:228</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a2be91ea87c7095558a2e678e750b467d"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a2be91ea87c7095558a2e678e750b467d">Bloomberg::quantum::Dispatcher::getNumCoroutineThreads</a></div><div class="ttdeci">int getNumCoroutineThreads() const</div><div class="ttdoc">Returns the number of underlying coroutine threads as specified in the constructor....</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:267</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a5d990ec39694d86dd8f5df1f5c50d65c"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a5d990ec39694d86dd8f5df1f5c50d65c">Bloomberg::quantum::Dispatcher::resetStats</a></div><div class="ttdeci">void resetStats()</div><div class="ttdoc">Resets all coroutine and IO queue counters.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:292</div></div>
<div class="ttc" id="structBloomberg_1_1quantum_1_1ThreadContextTag_html"><div class="ttname"><a href="../../de/de9/structBloomberg_1_1quantum_1_1ThreadContextTag.html">Bloomberg::quantum::ThreadContextTag</a></div><div class="ttdef"><b>Definition:</b> quantum_icontext_base.h:26</div></div>
<div class="ttc" id="structBloomberg_1_1quantum_1_1Functions_html_a4f8eb1de73c9ec3661fee4242f1a2a87"><div class="ttname"><a href="../../d0/d25/structBloomberg_1_1quantum_1_1Functions.html#a4f8eb1de73c9ec3661fee4242f1a2a87">Bloomberg::quantum::Functions::ReduceFunc</a></div><div class="ttdeci">std::function&lt; std::pair&lt; KEY, REDUCED_TYPE &gt;(std::pair&lt; KEY, std::vector&lt; MAPPED_TYPE &gt; &gt; &amp;&amp;)&gt; ReduceFunc</div><div class="ttdef"><b>Definition:</b> quantum_functions.h:40</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_af9281ee1e58963babb99304bc9cf3f16"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#af9281ee1e58963babb99304bc9cf3f16">Bloomberg::quantum::Dispatcher::forEach</a></div><div class="ttdeci">ThreadContextPtr&lt; std::vector&lt; RET &gt; &gt; forEach(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc&lt; RET, INPUT_IT &gt; func)</div><div class="ttdoc">Applies the given unary function to all the elements in the range [first,last). This function runs in...</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:106</div></div>
<div class="ttc" id="namespaceBloomberg_1_1quantum_html_a742e0d39218b80ae60f30d47ae58bbc9"><div class="ttname"><a href="../../dc/d48/namespaceBloomberg_1_1quantum.html#a742e0d39218b80ae60f30d47ae58bbc9">Bloomberg::quantum::ThreadFuturePtr</a></div><div class="ttdeci">typename IThreadFuture&lt; T &gt;::Ptr ThreadFuturePtr</div><div class="ttdef"><b>Definition:</b> quantum_ithread_future.h:69</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a0fee5233633dcf411120ce0d9bbe683f"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a0fee5233633dcf411120ce0d9bbe683f">Bloomberg::quantum::Dispatcher::getNumIoThreads</a></div><div class="ttdeci">int getNumIoThreads() const</div><div class="ttdoc">Returns the number of underlying IO threads as specified in the constructor.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:273</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a3f75cbfc894f962fcf6ff946154ece0c"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a3f75cbfc894f962fcf6ff946154ece0c">Bloomberg::quantum::Dispatcher::getCoroQueueIdRangeForAny</a></div><div class="ttdeci">const std::pair&lt; int, int &gt; &amp; getCoroQueueIdRangeForAny() const</div><div class="ttdoc">Gets the range [minQueueId, maxQueueId] of coroutine queueIds covered by IQueue::QueueId::Any when us...</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:279</div></div>
<div class="ttc" id="structBloomberg_1_1quantum_1_1Traits_html_a426371df215f96d490ba45c21f651468"><div class="ttname"><a href="../../d6/d86/structBloomberg_1_1quantum_1_1Traits.html#a426371df215f96d490ba45c21f651468">Bloomberg::quantum::Traits::IsInputIterator</a></div><div class="ttdeci">std::enable_if_t&lt; std::is_convertible&lt; typename std::iterator_traits&lt; IT &gt;::iterator_category, std::input_iterator_tag &gt;::value &gt; IsInputIterator</div><div class="ttdef"><b>Definition:</b> quantum_traits.h:62</div></div>
<div class="ttc" id="structBloomberg_1_1quantum_1_1ITask_html"><div class="ttname"><a href="../../df/daf/structBloomberg_1_1quantum_1_1ITask.html">Bloomberg::quantum::ITask</a></div><div class="ttdoc">Interface to a task. For internal use only.</div><div class="ttdef"><b>Definition:</b> quantum_itask.h:32</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a2871b47899d42838de63bbc94f088bbe"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a2871b47899d42838de63bbc94f088bbe">Bloomberg::quantum::Dispatcher::Dispatcher</a></div><div class="ttdeci">DEPRECATED Dispatcher(int numCoroutineThreads=-1, int numIoThreads=5, bool pinCoroutineThreadsToCores=false)</div><div class="ttdoc">Constructor.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:28</div></div>
<div class="ttc" id="namespaceBloomberg_1_1quantum_html_aa26dcdfb6c3930c1cd2b4000d8711f4c"><div class="ttname"><a href="../../dc/d48/namespaceBloomberg_1_1quantum.html#aa26dcdfb6c3930c1cd2b4000d8711f4c">Bloomberg::quantum::ThreadContextPtr</a></div><div class="ttdeci">typename IThreadContext&lt; RET &gt;::Ptr ThreadContextPtr</div><div class="ttdef"><b>Definition:</b> quantum_ithread_context.h:242</div></div>
<div class="ttc" id="classclass_html"><div class="ttname"><a href="../../d9/d6d/classclass.html">class</a></div><div class="ttdoc">Configuration parameters for the Quantum library.</div></div>
<div class="ttc" id="classBloomberg_1_1quantum_1_1Dispatcher_html_a841e9603a79d9feafc91a3a764e8a7d1"><div class="ttname"><a href="../../d0/da5/classBloomberg_1_1quantum_1_1Dispatcher.html#a841e9603a79d9feafc91a3a764e8a7d1">Bloomberg::quantum::Dispatcher::size</a></div><div class="ttdeci">size_t size(IQueue::QueueType type=IQueue::QueueType::All, int queueId=(int) IQueue::QueueId::All) const</div><div class="ttdoc">Returns the total number of queued tasks for the specified type and queue id.</div><div class="ttdef"><b>Definition:</b> quantum_dispatcher_impl.h:221</div></div>
</div><!-- fragment --></div><!-- contents -->
</div><!-- doc-content -->
<!-- start footer part -->
<div id="nav-path" class="navpath"><!-- id is needed for treeview function! -->
  <ul>
    <li class="navelem"><a class="el" href="../../dir_68267d1309a1af8e8297ef4c3efbcdba.html">src</a></li><li class="navelem"><b>quantum_dispatcher.h</b></li>
    <li class="footer">Generated by
    <a href="http://www.doxygen.org/index.html">
    <img class="footer" src="../../doxygen.png" alt="doxygen"/></a> 1.8.15 </li>
  </ul>
</div>
</body>
</html>
